#ifndef __APP_MQTT_H__
#define __APP_MQTT_H__

#include "MQTTClient.h"
#include "../thirdparty/log/log.h"


typedef int (*receCallback)(char*,int);

/**
 * @brief MQTT客户端初始化
 */
int app_mqtt_init(void);

/**
 * @brief MQTT客户端发送数据
 * @return 0:成功，-1:失败
 */
int app_mqtt_send(char* data,int len);

/**
 * @brief MQTT客户端断开连接
 */
void app_mqtt_close(void);

/**
 * @brief 注册接收回调函数
 * @param callback 回调函数
 */
void app_mqtt_resigterRecvCallBack(receCallback callback);

#endif /* __APP_MQTT_H__ */